package com.emqx.kafka.demo.service;

/**
 * kafka消息服务发送
 *
 * @author David
 * @date 2022/4/12 10:10
 */
public interface IKafkaService {

    /**
     * 根据配置mq配置发送消息
     */
    void sendMessageByConfig(String mqTopic, String messageJson);
}
